package com.fulihui.wgj.consumer.config.property;

import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * @author: LiuJie
 * @version: 2018/8/6 16:16
 * @description: 接入游戏 kafka
 */
@Component
@Data
public class GameKafkaProperties {

    @Value("${game.kafka.kafkaAddress}")
    String kafkaAddress;

    @Value("${game.kafka.groupName}")
    String groupName;

    @Value("${game.kafka.autoOffsetReset}")
    String autoOffsetReset;

    @Value("${game.kafka.sessionTimeOutMS}")
    String sessionTimeOutMS;

    @Value("${game.kafka.maxPollRecords}")
    Integer maxPollRecords;

    @Value("${game.kafka.topic.GameUserInfo}")
    String topicForGameUserInfo;
}
